package com.jugheadzhou.influxdb2test.consumer;

import lombok.extern.slf4j.Slf4j;
import org.springframework.kafka.annotation.KafkaListener;

/**
 * kafka消费
 *
 * @author jugheadzhou
 * @date 2022-10-26
 */
@Slf4j
public class KafkaConsumer {

    /**
     * 处理消息模板方法
     *
     * @param content
     */
    @KafkaListener(topics = "influx.test")
    public void handle(String content) {
        log.warn("Received kafka content: {}", content);
    }



}
